package org.mcclone.jr.spark.fs;

import org.apache.spark.sql.SparkSession;

public class FileRead {

    public static void main(String[] args) {
        SparkSession spark = SparkSession
                .builder()
                .master("local")
//                .config("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
                .appName("JavaStructuredKafkaWordCount")
                .getOrCreate();

        spark.read().orc("/user/McClone/my-file.orc").show();
    }
}
